package org.teremail.smtp;

import org.teremail.delivery.Exchange;

public class MessageDataConsumerFactory implements DataConsumerFactory {

    private final Exchange exchange;

    public MessageDataConsumerFactory(Exchange exchange) {
        this.exchange = exchange;
    }

    public MessageDataConsumer create(SMTPSession session) {
        return new MessageDataConsumer(session, exchange);
    }

}
